@@ -230,6 +230,7 @@ module Agents |
||
| 230 | 230 |
|
| 231 | 231 |
def check |
| 232 | 232 |
each_unread_mail { |mail, notified|
|
| 233 |
+ message_id = mail.message_id |
|
| 233 | 234 |
body_parts = mail.body_parts(mime_types) |
| 234 | 235 |
matched_part = nil |
| 235 | 236 |
matches = {}
|
@@ -277,7 +278,9 @@ module Agents |
||
| 277 | 278 |
end |
| 278 | 279 |
} or next |
| 279 | 280 |
|
| 280 |
- unless notified.include?(mail.message_id) |
|
| 281 |
+ if notified.include?(mail.message_id) |
|
| 282 |
+ log 'Ignoring mail: %s (already notified)' % message_id |
|
| 283 |
+ else |
|
| 281 | 284 |
matched_part ||= body_parts.first |
| 282 | 285 |
|
| 283 | 286 |
if matched_part |
@@ -288,6 +291,8 @@ module Agents |
||
| 288 | 291 |
body = '' |
| 289 | 292 |
end |
| 290 | 293 |
|
| 294 |
+ log 'Emitting an event for mail: %s' % message_id |
|
| 295 |
+ |
|
| 291 | 296 |
create_event :payload => {
|
| 292 | 297 |
'folder' => mail.folder, |
| 293 | 298 |
'subject' => mail.subject, |